//package com.atguigu.gmall.realtime.test;
//
//import org.apache.doris.flink.cfg.DorisExecutionOptions;
//import org.apache.doris.flink.cfg.DorisOptions;
//import org.apache.doris.flink.cfg.DorisReadOptions;
//import org.apache.doris.flink.sink.DorisSink;
//import org.apache.doris.flink.sink.writer.SimpleStringSerializer;
//import org.apache.flink.streaming.api.datastream.DataStreamSource;
//
//import java.util.Properties;
//
///**
// * Created by 黄凯 on 2023/7/14 0014 15:03
// *
// * @author 黄凯
// * 永远相信美好的事情总会发生.
// */
//public class T1 {
//
//    public static void main(String[] args) {
//
//        DataStreamSource<String> source = env
//                .fromElements(
//                        "{\"siteid\": \"550\", \"citycode\": \"1001\", \"username\": \"ww\",\"pv\": \"100\"}");
//        Properties props = new Properties();
//        props.setProperty("format", "json");
//        props.setProperty("read_json_by_line", "true"); // 每行一条 json 数据
//
//        DorisSink<String> sink = DorisSink.<String>builder()
//                .setDorisReadOptions(DorisReadOptions.builder().build())
//                .setDorisOptions(DorisOptions.builder() // 设置 doris 的连接参数
//                        .setFenodes("hadoop102:7030")
//                        .setTableIdentifier("test.table1")
//                        .setUsername("root")
//                        .setPassword("aaaaaa")
//                        .build())
//                .setDorisExecutionOptions(
//                        DorisExecutionOptions.builder() // 执行参数
//                        //.setLabelPrefix("doris-label")  // stream-load 导入的时候的 label 前缀
//                        .disable2PC() // 开启两阶段提交后,labelPrefix 需要全局唯一,为了测试方便禁用两阶段提交
//                        .setDeletable(false)
//                        .setBufferCount(3) // 批次条数: 默认 3
//                        .setBufferSize(8 * 1024) // 批次大小: 默认 1M
//                        .setCheckInterval(3000) // 批次输出间隔   三个对批次的限制是或的关系
//                        .setMaxRetries(3)
//                        .setStreamLoadProp(props) // 设置 stream load 的数据格式 默认是 csv,根据需要改成 json
//                        .build())
//                .setSerializer(new SimpleStringSerializer())
//                .build();
//        source.sinkTo(sink);
//
//    }
//
//}
